package org.lzfto.flink.demo.business.flinkTest.base.db;

public class StandardJdbcTable extends BasicJdbcTable {
	
	public  String build() throws Exception {
		if (this.getConnector()==null) {
			throw new Exception("请先设置连接器connector属性");
		}
		//标准SQL;
		String result = """
				with(
				  'connector'='%s',
				  'url' = '%s',
				  'table-name' = '%s',
				  'username' = '%s',
				  'password' = '%s'
				)
				""".formatted(
						this.getConnector(),
						this.getUrl(),
						this.getTableName(),
						this.getUserName(),
						this.getPassword()
						);
		return result;
	}

}
